package cn.sx.guoxd.springboot.service;

//import cn.sx.guoxd.springboot.dao.DaoA;
//import cn.sx.guoxd.springboot.model.User;
import io.reactivex.rxjava3.core.Observable;
import io.reactivex.rxjava3.subjects.PublishSubject;
//import org.apache.ibatis.session.RowBounds;
//import tk.mybatis.mapper.entity.Example;


public class ServiceA {
    private PublishSubject<String> subject = PublishSubject.create();
    public Observable<String> MyEvent = subject;

//    private DaoA daoA;
    public void method1(){
        System.out.println("method1");
        subject.onNext("abcde");
//        Example example = new Example(User.class);
//        Example.Criteria cr = example.createCriteria();
//        cr.andEqualTo("name","张三");
//
//        RowBounds rowBounds = new RowBounds(5,10);
//        daoA.selectByExampleAndRowBounds(example,rowBounds);
    }
}
